package cn.zwx.common.canal.service;

import com.alibaba.otter.canal.client.CanalConnector;

/**
 * @author zhangwenxue
 */
public interface CanalHandlerService {

    /**
     * processBinlog
     * @param destination destination
     * @param canalConnector canalConnector
     */
    void processBinlog(String destination, CanalConnector canalConnector);

}
